
package cn.hz.camel;

import java.io.Serializable;
import java.sql.Timestamp;
import java.util.Date;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

 

public class MzClientOutput  {
   private String key;
   
   private   LinkedBlockingQueue outQu=MzSource.outQu;
   

   public void exe(){
	   try{
		   MzMessage message=(MzMessage)outQu.poll(MzCfg.handQuTimeOut, TimeUnit.MINUTES);
		   message.getHandle().outHandle1(message);
		   
	   }catch(Exception e){
		   e.printStackTrace();
	   }
   }
   
   
   
}
